/**
 * Copyright (C) 2010, 2011 Neofonie GmbH
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package eu.dicodeproject.analysis.export;

import java.io.IOException;

import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.mapreduce.TableMapper;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

/**
 * Write column content to HDFS.
 */
public class TwitterExportMapper extends TableMapper<Text, Text> {

  private Text rowKey = new Text();
  private Text tweet = new Text();

  @Override
  protected void map(ImmutableBytesWritable row, Result values, Mapper.Context context) throws IOException,
      InterruptedException {

    for (KeyValue keyValue : values.list()) {
      tweet.set(keyValue.getValue());
      rowKey.set(row.get());
      context.write(rowKey, tweet);
    }
  }
}
